package bootsxt.websocket;

import bootsxt.utils.Kafka;
import bootsxt.utils.MsgType;
import org.springframework.web.bind.annotation.RestController;
import org.yeauty.annotation.*;
import org.yeauty.pojo.Session;

import java.io.IOException;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Function;

/**
 * 音频WebSocket端点。
 */
@RestController
@ServerEndpoint(path = "/ws/audio", corsOrigins = "*", port = "2222", maxFramePayloadLength = "655359")
public class AudioWebSocket extends WebSocketBase {

    @Override
    protected MsgType getMsgType() {
        return MsgType.AUDIO;
    }
}
